// 配置文件
const env = require('../config/config.js');

// 签名算法库
const Base64 = require('../libs/Base64.js');
require('../libs/hmac.js');
require('../libs/sha1.js');
const Crypto = require('../libs/crypto.js');

/**
 * 通用上传器
 * @description 接收微信文件临时路径filePath上传到oss
 * @param {String} filePath - 临时路径(例如: http://tmp/24f3.png)
 * @param {String} dir - 文件目录(例如: wechat/test)
 * @param {String} name - 文件名及后缀(例如: phone.png)
 * @param {Function} success - 成功回调
 * @param {Function} fail - 失败回调
 * @return void
 */
const uploadFile = function (params) {
  // 这里可以做一些文件判断及错误处理
  // 如果文件不合规,直接返回return结束函数不要往下走
  // ...

  // 设置文件上传至OSS后的文件路径(根据需求进行拼接url)
  const aliyunFileKey = `${params.dir}/${params.name}`;

  // 设置参数数据及算法
  const aliyunServerURL = env.uploadImageUrl;
  const accessid = env.OSSAccessKeyId;
  const policyBase64 = getPolicyBase64();
  const signature = getSignature(policyBase64);

  // 可在这里打印查看一些参数
  console.log(`[完整路径] ${aliyunServerURL}/${aliyunFileKey}`)
  // ...

  // oss要求的参数详见文档:https://help.aliyun.com/document_detail/92883.html#section-r7s-iqf-vn4
  wx.uploadFile({
    url: aliyunServerURL, //阿里云OSS地址(支持自定义域名)
    filePath: params.filePath,//临时路径
    name: 'file',//固定写法
    formData: {//要的参数,详见文档
      'key': aliyunFileKey,
      'policy': policyBase64,
      'OSSAccessKeyId': accessid,
      'signature': signature,
      'success_action_status': '200',
    },
    // 上传成功
    success: (res) => {
      // 失败回调
      if (res.statusCode != 200) {
        if(params.fail){
          params.fail(res)
        }
        return;
      }
      // 成功回调
      if(params.success){
        // 把你想扔出去的参数写里
        // params.success(aliyunFileKey);
        params.success({
          code: 200, msg: '上传成功',//状态码
          oss_url: aliyunServerURL,//上传到的阿里云oss地址
          oss_file: `${aliyunServerURL}/${aliyunFileKey}`,//完整上传路径
          // 加入你想返回的参数
          // ...
        });
      }
    },
    // 上传失败
    fail: (err) => {
      err.wxaddinfo = aliyunServerURL;
      if (params.fail) {
        params.fail(err)
      }
    },
  })
}

const getPolicyBase64 = function () {
  let date = new Date();
  date.setHours(date.getHours() + env.timeout);
  let srcT = date.toISOString();
  const policyText = {
    "expiration": srcT, //设置该Policy的失效时间
    "conditions": [
      ["content-length-range", 0, 20 * 1024 * 1024] // 设置上传文件的大小限制,5mb
    ]
  };
  const policyBase64 = Base64.encode(JSON.stringify(policyText));
  return policyBase64;
}

const getSignature = function (policyBase64) {
  const accesskey = env.AccessKeySecret;
  const bytes = Crypto.HMAC(Crypto.SHA1, policyBase64, accesskey, {
    asBytes: true
  });
  const signature = Crypto.util.bytesToBase64(bytes);
  return signature;
}

module.exports = uploadFile;
